package com.wfg.bigdata.spark.sql

import org.apache.spark.SparkConf
import org.apache.spark.sql.expressions.Aggregator
import org.apache.spark.sql._

object Spark04_SparkSQL_JDBC {

    def main(args: Array[String]): Unit = {

        // TODO 创建SparkSQL的运行环境
        val sparkConf = new SparkConf().setMaster("local[*]").setAppName("sparkSQL")
        val spark = SparkSession.builder().config(sparkConf).getOrCreate()
        import spark.implicits._

        // 读取MySQL数据
        val df = spark.read
                .format("jdbc")
                .option("url", "jdbc:mysql://11.158.74.82:3306/components_v3")
                .option("driver", "com.mysql.jdbc.Driver")
                .option("user", "root")
                .option("password", "123456")
                .option("dbtable", "app_sys_info")
                .load()
        df.show

        // 保存数据
//        df.write
//                .format("jdbc")
//                .option("url", "jdbc:mysql://11.158.74.82:3306/components_v3")
//                .option("driver", "com.mysql.jdbc.Driver")
//                .option("user", "root")
//                .option("password", "123456")
//                .option("dbtable", "app_sys_info")
//                .mode(SaveMode.Append)
//                .save()


        // TODO 关闭环境
        spark.close()
    }
}
